Node / ReticulumProjects / MeshChatX.git / files / vendor / rns_filesync / rns_filesync / protocol.py

Displaying Raw • Download

T8b949e"""Control-plane message encode and decode."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72from T7ee787typing Tff7b72import Te6edf3Any

Tff7b72from T7ee787RNST7ee787.T7ee787vendor Tff7b72import Te6edf3umsgpack

Te6edf3MSG_FILE_LIST Tff7b72= Ta5d6ff"Ta5d6fffile_listTa5d6ff"

Te6edf3MSG_FILE_LIST_REQUEST Tff7b72= Ta5d6ff"Ta5d6fffile_list_requestTa5d6ff"

Te6edf3MSG_FILE_REQUEST Tff7b72= Ta5d6ff"Ta5d6fffile_requestTa5d6ff"

Te6edf3MSG_DELTA_REQUEST Tff7b72= Ta5d6ff"Ta5d6ffdelta_requestTa5d6ff"

Te6edf3MSG_EMPTY_FILE Tff7b72= Ta5d6ff"Ta5d6ffempty_fileTa5d6ff"

Te6edf3MSG_FILE_UPDATE Tff7b72= Ta5d6ff"Ta5d6fffile_updateTa5d6ff"

Te6edf3MSG_FILE_DELETION Tff7b72= Ta5d6ff"Ta5d6fffile_deletionTa5d6ff"

Te6edf3KNOWN_TYPES Tff7b72= Tffa657frozensetTb4b4b4(

Tb4b4b4{

Te6edf3MSG_FILE_LISTTb4b4b4,

Te6edf3MSG_FILE_LIST_REQUESTTb4b4b4,

Te6edf3MSG_FILE_REQUESTTb4b4b4,

Te6edf3MSG_DELTA_REQUESTTb4b4b4,

Te6edf3MSG_EMPTY_FILETb4b4b4,

Te6edf3MSG_FILE_UPDATETb4b4b4,

Te6edf3MSG_FILE_DELETIONTb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tff7b72class T56d364ProtocolErrorTb4b4b4(Tf85149ValueErrorTb4b4b4)Tb4b4b4:

T8b949e"""Raised for invalid protocol messages."""

Tff7b72def Td2a8ffencode_messageTb4b4b4(Te6edf3payloadTb4b4b4: Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3payloadTb4b4b4, Tffa657dictTb4b4b4) Tff7b72or Ta5d6ff"Ta5d6fftypeTa5d6ff" Tff7b72not Tff7b72in Te6edf3payloadTb4b4b4:

Tff7b72raise Te6edf3ProtocolErrorTb4b4b4(Ta5d6ff"Ta5d6ffmessage must be a dict with typeTa5d6ff"Tb4b4b4)

Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Te6edf3payloadTb4b4b4)

Tff7b72def Td2a8ffdecode_messageTb4b4b4(Te6edf3rawTb4b4b4: Tffa657bytesTb4b4b4) Tff7b72-Tff7b72> Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4:

Te6edf3data Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3dataTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:

Tff7b72raise Te6edf3ProtocolErrorTb4b4b4(Ta5d6ff"Ta5d6ffmessage must unpack to dictTa5d6ff"Tb4b4b4)

Te6edf3msg_type Tff7b72= Te6edf3dataTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4)

Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3msg_typeTb4b4b4, Tffa657strTb4b4b4) Tff7b72or Te6edf3msg_type Tff7b72not Tff7b72in Te6edf3KNOWN_TYPESTb4b4b4:

Tff7b72raise Te6edf3ProtocolErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffunknown message type: Tffd700{Te6edf3msg_typeTffd700!r}Ta5d6ff"Tb4b4b4)

Tff7b72return Te6edf3data

Tff7b72def Td2a8ffmake_file_listTb4b4b4(Te6edf3filesTb4b4b4: Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4]Tb4b4b4, Te6edf3browserTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_FILE_LISTTb4b4b4,

Ta5d6ff"Ta5d6fffilesTa5d6ff"Tb4b4b4: Te6edf3filesTb4b4b4,

Ta5d6ff"Ta5d6ffbrowserTa5d6ff"Tb4b4b4: Tffa657boolTb4b4b4(Te6edf3browserTb4b4b4)Tb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffmake_file_list_requestTb4b4b4(Te6edf3browserTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(Tb4b4b4{Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_FILE_LIST_REQUESTTb4b4b4, Ta5d6ff"Ta5d6ffbrowserTa5d6ff"Tb4b4b4: Tffa657boolTb4b4b4(Te6edf3browserTb4b4b4)Tb4b4b4}Tb4b4b4)

Tff7b72def Td2a8ffmake_file_requestTb4b4b4(Te6edf3pathTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(Tb4b4b4{Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_FILE_REQUESTTb4b4b4, Ta5d6ff"Ta5d6ffpathTa5d6ff"Tb4b4b4: Te6edf3pathTb4b4b4}Tb4b4b4)

Tff7b72def Td2a8ffmake_delta_requestTb4b4b4(Te6edf3pathTb4b4b4: Tffa657strTb4b4b4, Te6edf3local_blocksTb4b4b4: Tffa657listTb4b4b4[Tffa657strTb4b4b4]Tb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_DELTA_REQUESTTb4b4b4,

Ta5d6ff"Ta5d6ffpathTa5d6ff"Tb4b4b4: Te6edf3pathTb4b4b4,

Ta5d6ff"Ta5d6fflocal_blocksTa5d6ff"Tb4b4b4: Tffa657listTb4b4b4(Te6edf3local_blocksTb4b4b4)Tb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffmake_empty_fileTb4b4b4(Te6edf3pathTb4b4b4: Tffa657strTb4b4b4, Te6edf3file_hashTb4b4b4: Tffa657str Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_EMPTY_FILETb4b4b4,

Ta5d6ff"Ta5d6ffpathTa5d6ff"Tb4b4b4: Te6edf3pathTb4b4b4,

Ta5d6ff"Ta5d6ffhashTa5d6ff"Tb4b4b4: Te6edf3file_hashTb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffmake_file_updateTb4b4b4(Te6edf3pathTb4b4b4: Tffa657strTb4b4b4, Te6edf3infoTb4b4b4: Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_FILE_UPDATETb4b4b4,

Ta5d6ff"Ta5d6ffpathTa5d6ff"Tb4b4b4: Te6edf3pathTb4b4b4,

Ta5d6ff"Ta5d6ffinfoTa5d6ff"Tb4b4b4: Te6edf3infoTb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffmake_file_deletionTb4b4b4(Te6edf3pathTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3encode_messageTb4b4b4(Tb4b4b4{Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Te6edf3MSG_FILE_DELETIONTb4b4b4, Ta5d6ff"Ta5d6ffpathTa5d6ff"Tb4b4b4: Te6edf3pathTb4b4b4}Tb4b4b4)

Tff7b72def Td2a8ffdecode_metadata_valueTb4b4b4(Te6edf3valueTb4b4b4: Te6edf3AnyTb4b4b4) Tff7b72-Tff7b72> Te6edf3AnyTb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657bytesTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72return Te6edf3valueTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tff7b72except Tf85149UnicodeDecodeErrorTb4b4b4:

Tff7b72return Te6edf3valueTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)

Tff7b72return Te6edf3value